package org.example;

import javax.servlet.annotation.WebServlet;
import javax.servlet.http.*;
import java.io.IOException;

@WebServlet("/Main")
public class Main extends HttpServlet {
    @Override
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws IOException {
        // 获取用户名称和消息
        String userName = new String(request.getParameter("userName").getBytes("ISO-8859-1"), "UTF-8");
        String message = new String(request.getParameter("message").getBytes("ISO-8859-1"), "UTF-8");

        // SQL 插入语句
        String sql = "INSERT INTO ChatMessages (UserName, MessageText) VALUES (?, ?)";

        // 使用 DBUtil 的 executePreparedUpdate 方法插入数据
        int result = DBUtil.executePreparedUpdate(sql, userName, message);

        // 根据操作结果进行相应处理
        if (result > 0) {
            System.out.println("消息已成功保存到数据库");
        } else {
            System.out.println("保存消息失败");
        }

        // 可以选择重定向到聊天页面或者输出某些信息
        response.sendRedirect("index.jsp");
    }
}